﻿namespace MySqlSync.Core.Interfaces
{
    /// <summary>
    /// 同步消费者服务接口
    /// 定义了从Kafka接收同步数据并应用到目标数据库的核心功能
    /// </summary>
    public interface ISyncConsumerService
    {
        /// <summary>
        /// 启动消费者服务
        /// 开始监听Kafka主题并处理接收到的同步记录
        /// </summary>
        /// <param name="cancellationToken">用于取消操作的令牌</param>
        /// <returns>表示异步操作的任务</returns>
        Task StartAsync(CancellationToken cancellationToken);
    }
}
